bb9f0972c879967b9aaa8848b7f18067caabf87f,server/src/main/java/com/orientechnologies/orient/server/distributed/conflict/ODefaultReplicationConflictResolver.java,ODefaultReplicationConflictResolver,reset,#,193
Before Change
@Override
public ODocument reset() {
ODatabaseRecordThreadLocal.INSTANCE.set((ODatabaseRecord) database);
final int deleted = database.command(new OSQLSynchQuery<OIdentifiable>("delete from " + DISTRIBUTED_CONFLICT_CLASS));
return new ODocument().field("result", deleted);
}
After Change
@Override
public ODocument reset() {
ODatabaseRecordThreadLocal.INSTANCE.set((ODatabaseRecord) database);
final int deleted = (Integer) database.command(new OSQLSynchQuery<OIdentifiable>("delete from " + DISTRIBUTED_CONFLICT_CLASS))
.execute();
return new ODocument().field("result", deleted);
}